import mysql from "mysql";
import config from "./config";

/**
 * 数据源
 */
 class DataSource {

    constructor() {
        //创建链接mysql的连接池
        //console.log("创建连接池")
        this.pool = mysql.createPool(config);

    }



    /**
     * 同步获取
     * @returns {Promise<unknown>}
     */
    getConnectionSync(){
        return new Promise((resolve, reject) => {
            this.pool.getConnection((err, conn) => {
                if (err) {
                    reject(err);
                } else {
                    resolve(conn);
                }
            })
        })
    }
}

module.exports = new DataSource();
